22624a1d5fc452775ca1644d28b46374844d3248,datumbox-framework-core/src/main/java/com/datumbox/framework/core/machinelearning/clustering/Kmeans.java,Kmeans,_predictDataset,#Dataframe#,435
Before Change
/** {@inheritDoc} */
@Override
protected void _predictDataset(Dataframe newData) {
DatabaseConnector dbc = knowledgeBase.getDbc();
Map<Integer, Prediction> resultsBuffer = dbc.getBigMap("tmp_resultsBuffer", Integer.class, Prediction.class, MapType.HASHMAP, StorageHint.IN_DISK, true, true);
_predictDatasetParallel(newData, resultsBuffer, knowledgeBase.getConf().getConcurrencyConfig());
dbc.dropBigMap("tmp_resultsBuffer", resultsBuffer);
}
/** {@inheritDoc} */
After Change
/** {@inheritDoc} */
@Override
protected void _predict(Dataframe newData) {
_predictDatasetParallel(newData, knowledgeBase.getDbc(), knowledgeBase.getConf().getConcurrencyConfig());
}
/** {@inheritDoc} */